package com.etl.dataflow.executor.core;

import com.etl.dataflow.executor.element.Row;

import java.util.List;

/**
 * 写后拦截器抽象类
 * Writer批量写入数据到目标表之后调用此拦截器
 *
 * @author dx
 */
public abstract class AbstractAfterWriteInterceptor implements Interceptor {

    /**
     * 写后拦截
     *
     * @param writtenRows 写入成功的记录
     * @param failedRows  写入失败的记录
     */
    public abstract void onAfterWrite(List<Row> writtenRows, List<Row> failedRows);

    /**
     * 所有记录写入完成时调用
     */
    public abstract void onWriteFinished();
}
